package com.changan.model;

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;

/**
 * flink rest api run接口参数
 * @author WY
 */
@Setter
@Getter
@AllArgsConstructor
@NoArgsConstructor
public class FlinkRunParam {

    /**
     * 任务ID
     */
    private String jobId;

    /**
     * 运行参数
     */
    private String programArgs;

    /**
     * 任务入口类
     */
    private String entryClass;

    /**
     * save point路径
     */
    private String savepointPath;

    /**
     *
     */
    private Boolean allowNonRestoredState;

    /**
     * 并行度
     */
    private Integer parallelism;
}
